package drds.data_propagate.parse;

/**
 * receive parsed bytes , 用于处理要解析的数据块
 */
public interface SinkFunction<Event> {

    public boolean sink(Event event);
}
